package com.its.common.kafka.consumer;

import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * @Author xiaxp
 * @Date 2021-11-10 20:53
 * @Description
 */
public class KafkaConsumerWorkerExample extends AbstractKafkaConsumerWorker {

    @Override
    public void handleRecord(ConsumerRecord record) {
        System.out.println("Thread - "+ Thread.currentThread().getName());
        System.err.printf("patition = %d , offset = %d, key = %s, value = %s%n",
                record.partition(), record.offset(), record.key(), record.value());
    }
}
